package queue

type Queue interface {
	Subscribe(channel string)
	Consume(channel string, cb []func(msg interface{})) error
}

func SetupAndConsume(queue Queue, channel string, cbs []func(msg interface{})) {
	queue.Consume(channel, cbs)
}
